package com.example.kafka.comsumer;

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.kafka.annotation.PartitionOffset;
import org.springframework.kafka.annotation.TopicPartition;

/**
 * @author zxs
 * @since 2021/10/11
 */
/*@KafkaListener(topics = "ds0",groupId = "test",topicPartitions = {
        @TopicPartition(topic = "test",partitions = {"0","1"},partitionOffsets = {
                @PartitionOffset(partition = "0",initialOffset = "10"),
                @PartitionOffset(partition = "1",initialOffset = "0")
        })
})*/
public class TestConsumer {
}
